package com.guanzi.big_data_mq_process.service;

import com.baomidou.mybatisplus.extension.service.IService;
import com.guanzi.big_data_mq_process.model.entity.TransactionMessage;
import com.guanzi.big_data_mq_process.model.enums.LocalTransactionStateEnum;
import com.guanzi.big_data_mq_process.model.enums.MessageStatusEnum;

/**
 * (TransactionMessage) 接口
 *
 * @author xuguang
 * @since 2025-05-07 14:41:50
 */
public interface ITransactionMessageService extends IService<TransactionMessage> {

    void updateTxState(String messageId, LocalTransactionStateEnum localTransactionStateEnum);

    void updateMsgStatus(String messageId, MessageStatusEnum messageStatusEnum);

    LocalTransactionStateEnum selectTxState(String messageId);
}
